cb409047bf66420872b47c49e4d4c091fa0e1881,src/be/ibridge/kettle/trans/step/cubeinput/CubeInput.java,CubeInput,processRow,#StepMetaInterface#StepDataInterface#,57
Before Change
{
Row r = new Row(data.dis, data.meta.size(), data.meta);
linesInput++;
putRow(r); // fill the rowset(s). (wait for empty)
if (meta.getRowLimit()>0 && linesInput>=meta.getRowLimit()) // finished!
{
After Change
if (first)
{
first=false;
r= data.meta;
}
else
{
r = new Row(data.dis, data.meta.size(), data.meta);
}
putRow(r); // fill the rowset(s). (sleeps if full)
linesInput++;
if (meta.getRowLimit()>0 && linesInput>=meta.getRowLimit()) // finished!